import pymysql,re

def query_mysql(sql_query):
    """执行 SQL 查询并返回结果"""
    try:
        # 1. 连接 MySQL 数据库（替换为你的数据库信息）
        connection = pymysql.connect(
            host="124.220.19.41",  # 数据库地址
            user="root",      # 用户名
            password="daitm123",  # 密码
            database="animal-plant-identification",  # 数据库名
            cursorclass=pymysql.cursors.DictCursor  # 返回字典格式
        )

        # 2. 执行 SQL 查询
        with connection.cursor() as cursor:
            cursor.execute(sql_query)
            result = cursor.fetchall()  # 获取所有结果

        # 3. 关闭连接
        connection.close()

        return result

    except Exception as e:
        print(f"❌ MySQL 查询出错: {e.args[1]}")
        return e.args[1]
    
# query_mysql("""
# SELECT a.*, ac.content
# FROM t_animal a
# JOIN t_animal_content ac ON a.id = ac.animal_id
# WHERE a.name = '丹顶鹤';
# """)